#!/bin/bash
#kafka存入hbase的数据导出到hdfs
#jar包路径
jarPath="./SparkTask-WordCount.jar"
#如果未启动，启动kafka消费者程序(拉kafka数据入hbase)
#java -jar $jarPath KafkaConsumerClient
#数据日期YYYYMMDD，自动取昨日数据

echo "文件名:$0"
str="$1"
yyyyMMdd=""
if ((${#str} == "8"))
then yyyyMMdd=$str
else yyyyMMdd=$(date -d "$str days ago" +%Y%m%d)
fi
echo "当前获取数据日期 $yyyyMMdd"

#拉第几天前的数据
#pastDays="1"
#下面代码基本不用动
#yyyyMMdd=$(date -d "$pastDays days ago" +%Y%m%d)
#hdfs路径前缀，固定不变
hdfsPathPrefix="/user/cq_qkjdyjc"
#本地存hdfs文件目录
localPath="/qkjdy/datax/bin/conf"
#电压hbase表名/写入文件名
V="cms_volt_curve_$yyyyMMdd"
#功率
P="cms_power_curve_$yyyyMMdd"
#电流
I="cms_cur_curve_$yyyyMMdd"
#无功
WG="dms_decloud_mlv_measuration_$yyyyMMdd"
#hbase写至hdfs
java -jar $jarPath HBaseToHdfs "$V" /hbaseData/"$V"
java -jar $jarPath HBaseToHdfs "$P" /hbaseData/"$P"
java -jar $jarPath HBaseToHdfs "$I" /hbaseData/"$I"
java -jar $jarPath WriteWGToTxt "$WG" /hbaseData/"$WG" PhW_phsA,PhW_phsB,PhW_phsC,PhVAr_phsA,PhVAr_phsB,PhVAr_phsC,TotW,TotVAr
#拉取hdfs至本地
hdfs dfs -get $hdfsPathPrefix/hbaseData/"$V" $localPath
hdfs dfs -get $hdfsPathPrefix/hbaseData/"$P" $localPath
hdfs dfs -get $hdfsPathPrefix/hbaseData/"$I" $localPath
hdfs dfs -get $hdfsPathPrefix/hbaseData/"$WG" $localPath
